package com.partsoft.dits.integrate;

import com.partsoft.dits.DataIntegrateProcessor;
import com.partsoft.dits.DataReceiver;
import com.partsoft.dits.TableDataEdgeDescriptor;
import com.partsoft.dits.dsm.DataSourceFactory;
import com.partsoft.dits.message.MessageProcessor;
import com.partsoft.dits.transform.TransformReactor;

public class BaseTableDataMessageReceiver extends
		AbstractTableDataMessageReceiver implements DataReceiver,
		DataIntegrateProcessor {

	private MessageProcessor messageProcessor = MessageProcessor.INSTANCE;
	
	private DataSourceFactory dataSourceFactory;
	
	private TableDataDescriptorRegistry<TableDataEdgeDescriptor> dataDescriptorRegistry;
	
	private TransformReactor transformReactor;

	public MessageProcessor getMessageProcessor() {
		return messageProcessor;
	}

	public void setMessageProcessor(MessageProcessor messageProcessor) {
		this.messageProcessor = messageProcessor;
	}

	public DataSourceFactory getDataSourceFactory() {
		return dataSourceFactory;
	}

	public void setDataSourceFactory(DataSourceFactory dataSourceFactory) {
		this.dataSourceFactory = dataSourceFactory;
	}

	public TableDataDescriptorRegistry<TableDataEdgeDescriptor> getDataDescriptorRegistry() {
		return dataDescriptorRegistry;
	}

	public void setDataDescriptorRegistry(
			TableDataDescriptorRegistry<TableDataEdgeDescriptor> dataDescriptorRegistry) {
		this.dataDescriptorRegistry = dataDescriptorRegistry;
	}

	public TransformReactor getTransformReactor() {
		return transformReactor;
	}

	public void setTransformReactor(TransformReactor transformReactor) {
		this.transformReactor = transformReactor;
	}

	
}
